package com.forchange.project.dao

import com.forchange.project.util.EnvUtil
import org.apache.spark.rdd.RDD

/**
 * @Author chencong
 * @Description   数据访问对象，专门负责和关系型数据库如mysql之间的交互
 * @Date 2:38 下午 2021/6/27
 * @Param
 * */
trait TDAO {
  def readFile(path:String) ={
    val fileRDD: RDD[String] = EnvUtil.getEnv().textFile(path)
    fileRDD
  }
}
